# 主程序
from celery import Celery

app = Celery("meiduo")

# 因为发送短信的任务中需要使用到django的配置信息
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo_mall.settings.dev'

# 加载配置信息
app.config_from_object("celery_tasks.config")

# 声明获取异步任务的队列[目录中必须有一个tasks.py文件，这个就是任务文件]
app.autodiscover_tasks(["celery_tasks.sms"])


# 在终端下执行一下命令
# celery -A 主程序路径 worker -l info
# 在当前项目中，命令就是
# 在meiduo_mall/meiduo_mall这个目录中运行
# celery -A celery_tasks.main worker -l info